package com.itheima.stream.config;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @Description:
 * @Version: V1.0
 */
public interface MySink {


    /**
     * Input channel name.
     */
    String INPUT = "stream_input";

    /**
     * @return input channel.
     */
    @Input(MySink.INPUT)
    SubscribableChannel input();


}
